// Copyright 2019 Andy Pan. All rights reserved.
// Use of this source code is governed by an MIT-style
// license that can be found in the LICENSE file.

// +build darwin netbsd freebsd openbsd dragonfly

package gnet

import (
	"github.com/panjf2000/gnet/netpoll"
)

func (lp *loop) handleEvent(fd int, filter int16) error {
	if c, ok := lp.connections[fd]; ok {
		switch c.opened {
		case false:
			return lp.loopOpen(c)
		case true:
			switch filter {
			// Don't change the ordering of processing EVFILT_WRITE | EVFILT_READ | EV_ERROR/EV_EOF unless you're 100%
			// sure what you're doing!
			// Re-ordering can easily introduce bugs and bad side-effects, as I found out painfully in the past.
			case netpoll.EVFilterWrite:
				if !c.outboundBuffer.IsEmpty() {
					return lp.loopOut(c)
				}
				return nil
			case netpoll.EVFilterRead:
				return lp.loopIn(c)
			case netpoll.EVFilterSock:
				return lp.loopCloseConn(c, nil)
			default:
				return nil
			}
		}
	}
	return lp.loopAccept(fd)
}
